package com.cn.broker.processor;

import com.cn.broker.BrokerController;
import com.cn.common.processor.INettyRequestProcessor;
import com.cn.msg.Message;
import io.netty.channel.ChannelHandlerContext;

public class ConsumerProcessor implements INettyRequestProcessor {

    private BrokerController brokerController;

    public ConsumerProcessor(BrokerController brokerController) {
        this.brokerController = brokerController;
    }

    @Override
    public Message process(Message message, ChannelHandlerContext ctx) {
        return null;
    }
}
